package com.example.thread.d9CompletableFuture2.d3异步任务回调;

import com.example.thread.d9CompletableFuture2.CommonUtils;

import java.util.Arrays;
import java.util.concurrent.CompletableFuture;

// thenApply()方法可以处理和转换CompletableFuture的结果，他以Function<T,R>作为参数，
// Function<T,R>是一个函数式接口，表示一个转换操作，他接受类型T的参数并参生类型R的结果,thenApply()方法支持链式操作
public class D1ThenApplyDemo {
    public static void main(String[] args) {
        CommonUtils.printThreadLog("main start");
        CompletableFuture<String[]> future = CompletableFuture.supplyAsync(() -> {
            CommonUtils.printThreadLog("读取文件操作开始");
            return CommonUtils.readFile("aaa,bbb,ccc,ddd");
        }).thenApply(content -> {
            CommonUtils.printThreadLog("转化为数组");
            return content.split(",");
        });

        String[] strings = future.join();

        System.out.println(Arrays.toString(strings));
        CommonUtils.printThreadLog("main end");

        /**
         * 总结： thenApply中回调任务和supplyAsync中的异步任务使用的是同一个线程
         */
    }
}
